/**
 * 
 */
package mapreduce4j;

import java.io.IOException;

import org.apache.hadoop.io.WritableComparable;

/**
 * @author tim
 *
 */
public abstract class RecordWriter <KEY_OUT extends WritableComparable, VALUE_OUT extends WritableComparable> {
	public abstract void write(KEY_OUT key, VALUE_OUT value) throws IOException, InterruptedException;
	public abstract void close() throws IOException, InterruptedException;
}
